www.gusucode.com > wxApp PHP版微信小程序CMS系统 v1.0PHP源码程序 > wxApp PHP版微信小程序CMS系统 v1.0/wxAppCMS_v1.0.0/wxAppCMS_v1.0.0/app/files/library/QiniuClient.class.php

    <?php
/**
 * @author https://github.com/chuck911/qiniu-php
 */
class QiniuClient
{
	const UP_HOST  = 'http://up.qiniu.com';
	const RS_HOST  = 'http://rs.qbox.me';
	const RSF_HOST = 'http://rsf.qbox.me';

	public $accessKey;
	public $secretKey;

	public function __construct($accessKey,$secretKey)
	{
		$this->accessKey = $accessKey;
		$this->secretKey = $secretKey;
	}

	public function uploadFile($filePath,$bucket,$key=null)
	{
		$data = array();
		$ch   = curl_init();
		if (class_exists('CURLFile',false)) {
		    defined('CURLOPT_SAFE_UPLOAD') && curl_setopt($ch, CURLOPT_SAFE_UPLOAD, true);
		    $data['file'] = new CURLFile($filePath);
		} else {
	        if (defined('CURLOPT_SAFE_UPLOAD')) {
	            if (version_compare('5.6',PHP_VERSION,'>=')) {
	                curl_setopt($ch, CURLOPT_SAFE_UPLOAD, false);
	            }
	        }
		    $data['file'] = "@$filePath";
		}
		// $data['file'] = "@$filePath";
		$data['token'] = $this->uploadToken(array('scope' => $bucket));
		if($key) $data['key'] = $key;

		curl_setopt($ch, CURLOPT_URL, self::UP_HOST);
		curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
		curl_setopt($ch, CURLOPT_POST, true);
		curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
		$result = curl_exec($ch);
		curl_close($ch);
		return $result;
	}

	public function upload($content,$bucket,$key=null)
	{
		$filePath = tempnam(sys_get_temp_dir(), 'UPLOAD');
		file_put_contents($filePath, $content);
		$result = $this->uploadFile($filePath,$bucket,$key);
		unlink($filePath);
		return $result;
	}

	public function uploadRemote($url,$bucket,$key=null)
	{
		$filePath = tempnam(sys_get_temp_dir(), 'UPLOAD');
		copy($url,$filePath);
		$result = $this->uploadFile($filePath,$bucket,$key);
		unlink($filePath);
		return $result;
	}

	public function stat($bucket,$key)
	{
		$encodedEntryURI = $this->urlsafe_base64_encode("{$bucket}:{$key}");
		$url = "/stat/{$encodedEntryURI}";
		return $this->fileHandle($url);
	}

	public function move($bucket,$key,$bucket2,$key2=false)
	{
		if(!$key2) {
			$key2 = $bucket2;
			$bucket2 = $bucket;
		}
		$encodedEntryURISrc = $this->urlsafe_base64_encode("{$bucket}:{$key}");
		$encodedEntryURIDest = $this->urlsafe_base64_encode("{$bucket2}:{$key2}");
		$url = "/move/{$encodedEntryURISrc}/{$encodedEntryURIDest}";
		return $this->fileHandle($url);
	}

	public function copy($bucket,$key,$bucket2,$key2=false)
	{
		if(!$key2) {
			$key2 = $bucket2;
			$bucket2 = $bucket;
		}
		$encodedEntryURISrc = $this->urlsafe_base64_encode("{$bucket}:{$key}");
		$encodedEntryURIDest = $this->urlsafe_base64_encode("{$bucket2}:{$key2}");
		$url = "/copy/{$encodedEntryURISrc}/{$encodedEntryURIDest}";
		return $this->fileHandle($url);
	}

	public function delete($bucket,$key)
	{
		$encodedEntryURI = $this->urlsafe_base64_encode("{$bucket}:{$key}");
		$url = "/delete/{$encodedEntryURI}";
		return $this->fileHandle($url);
	}

	// $operator = stat|move|copy|delete
	// $client->batch('stat',array('square:test/test5.txt','square:test/test13.png'));
	public function batch($operator,$files)
	{
		$data = '';
		foreach ($files as $file) {
			if(!is_array($file)) {
				$encodedEntryURI = $this->urlsafe_base64_encode($file);
				$data.="op=/{$operator}/{$encodedEntryURI}&";
			}else{
				$encodedEntryURI = $this->urlsafe_base64_encode($file[0]);
				$encodedEntryURIDest = $this->urlsafe_base64_encode($file[1]);
				$data.="op=/{$operator}/{$encodedEntryURI}/{$encodedEntryURIDest}&";
			}
		}
		return $this->fileHandle('/batch',$data);
	}

	public function listFiles($bucket,$limit='',$prefix='',$marker='')
	{
		$params = array_filter(compact('bucket','limit','prefix','marker'));
		$url = self::RSF_HOST.'/list?'.http_build_query($params);
		return $this->fileHandle($url);
	}

	public function fileHandle($url,$data=array())
	{
		if(strpos($url, 'http://')!==0) $url = self::RS_HOST.$url;

		if(is_array($data)) $accessToken = $this->accessToken($url);
		else $accessToken = $this->accessToken($url,$data);

		$ch = curl_init();
		curl_setopt($ch, CURLOPT_HTTPHEADER, array(
		    'Authorization: QBox '.$accessToken,
	    ));

	    curl_setopt($ch, CURLOPT_URL, $url);
	    curl_setopt($ch, CURLOPT_POST, true);
	    // If $data is an array, the Content-Type header will be set to multipart/form-data
	    curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
	    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
	    $result = curl_exec($ch);
	    $info = curl_getinfo($ch);
		curl_close($ch);

		if($info['http_code']>=300){
	        return json_encode(array(
	                'error' => $info['http_code'],
	                'msg'   => json_decode($result,true)
	        ));
		}
		if($info['content_type']=='application/json'){
			return json_decode($result,true);
		}

		return $result;
	}

	public function uploadToken($flags)
	{
		if(!isset($flags['deadline']))
			$flags['deadline'] = 3600 + time();
		$encodedFlags = $this->urlsafe_base64_encode(json_encode($flags));
		$sign = hash_hmac('sha1', $encodedFlags, $this->secretKey, true);
		$encodedSign = $this->urlsafe_base64_encode($sign);
	    $token = $this->accessKey.':'.$encodedSign. ':' . $encodedFlags;
	    return $token;
	}

	public function accessToken($url,$body=false){
	    $parsed_url = parse_url($url);
	    $path = $parsed_url['path'];
	    $access = $path;
	    if (isset($parsed_url['query'])) {
	        $access .= "?" . $parsed_url['query'];
	    }
	    $access .= "\n";
	    if($body) $access .= $body;
	    $digest = hash_hmac('sha1', $access, $this->secretKey, true);
	    return $this->accessKey.':'.$this->urlsafe_base64_encode($digest);
	}

	public function urlsafe_base64_encode($str){
	    $find = array("+","/");
	    $replace = array("-", "_");
	    return str_replace($find, $replace, base64_encode($str));
	}
}